package com.peter.cases.kafka;

import java.io.IOException;
import java.time.Duration;
import java.util.Properties;

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.utils.Timer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import com.peter.cases.communication.LiUncle;

@SpringBootApplication
public class KafkaApplication {

    public static void main(String[] args) {
        SpringApplication.run(KafkaApplication.class, args);

        try {
            new LiUncle().monitor(null);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}
